78a85047c71d53ad9ad74e5eed5b9ccf1d9cce36,samza-core/src/test/java/org/apache/samza/container/grouper/task/TestTaskAssignmentManager.java,TestTaskAssignmentManager,testTaskAssignmentManagerEmptyCoordinatorStream,#,139
Before Change
taskAssignmentManager.register(new TaskName("ignoredTaskName"));
assertTrue(producer.isRegistered());
assertEquals(producer.getRegisteredSource(), "SamzaTaskAssignmentManager");
assertTrue(consumer.isRegistered());
taskAssignmentManager.start();
assertTrue(producer.isStarted());
After Change
mockCoordinatorStreamSystemFactory.getCoordinatorStreamSystemProducer(config, null);
MockCoordinatorStreamSystemConsumer consumer =
mockCoordinatorStreamSystemFactory.getCoordinatorStreamSystemConsumer(config, null);
consumer.register();
TaskAssignmentManager taskAssignmentManager = new TaskAssignmentManager(producer, consumer);
assertTrue(producer.isRegistered());